package com.wlz.mq;

import com.wlz.config.ActiveMqConfig;
import lombok.extern.slf4j.Slf4j;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

/**
 * @author： wlz
 * @Date 2020/8/18 14:46
 * @description： TODO  消费端 接收消息
 * @version: 1.0
 */
@Component
@Slf4j
public class PtpConsumer {

    /**
     * 使用 JmsListener 配置消费者监听的队列，其中msg 是接收的消息
     * @param msg
     */
    @JmsListener(destination = ActiveMqConfig.ACTIVE_QUEUE)
    public void handleMessage(String msg) {
        try {
            // todo
            log.info("msg:"+msg);
        } catch (Exception e) {
            log.error("handleMessage",e);
        }
    }

}
